package com.deep.flink.demo.function;

import org.apache.flink.table.functions.ScalarFunction;

/**
 * （1）继承 ScalarFunction 并且实现一个或者多个求值方法
 * （2）标量函数的行为取决于你写的求值方法。求值方法必须是 public 的，而且名字必须是 eval。
 */
public class TestFunction extends ScalarFunction {

    public String eval(String var) {
        return var + " aaaaaaaaaa";
    }
}
